# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
from jms.time_sensor.time_after_04_00 import time_after_04_00

jms_dwd__dwd_wide_yl_rt_ssmx_bill_detail_hf_04 = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_dwd__dwd_wide_yl_rt_ssmx_bill_detail_hf_04",
    filepath='/dw/hive/jms_dim.db/external/dim_dependent/dt={{ execution_date | date_add(1) | cst_ds }}-03/dep=dwd_wide_yl_rt_ssmx_bill_detail_hf',
    execution_timeout = timedelta(minutes=60),
    email=['wangmenglei@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=0,
)
jms_dwd__dwd_wide_yl_rt_ssmx_bill_detail_hf_04  <<  time_after_04_00
